package com.源码分析;

import reactor.core.publisher.Flux;

public class DistinctDemo {

	public static void main(String[] args) {
		Flux.just(1, 2, 3, 4, 5, 2, 4, 2).distinct().subscribe(System.out::println);
		// 可用于无限流，以删除出现在不间断行中的重复项
		Flux.just(1, 2, 4, 4, 4, 2, 4, 2).distinctUntilChanged().subscribe(System.out::println);
	}

}
